44a09fdb19ec401324a90875f5d8f793b62cd2ac,modules/core/src/main/java/org/gridgain/grid/kernal/processors/hadoop/hadoop1impl/GridHadoopV1CombineTask.java,GridHadoopV1CombineTask,run,#GridHadoopTaskContext#,31

Before Change


    @Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
        GridHadoopV1JobImpl jobImpl = (GridHadoopV1JobImpl)taskCtx.job();

        JobContext jobCtx = jobImpl.hadoopJobContext();

        Reducer combiner = U.newInstance(jobCtx.getJobConf().getCombinerClass());

        combiner.configure(jobCtx.getJobConf());

        GridHadoopTaskInput input = taskCtx.input();

After Change


    @Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
        GridHadoopV2JobImpl jobImpl = (GridHadoopV2JobImpl) taskCtx.job();

        JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();

        Reducer combiner = U.newInstance(jobConf.getCombinerClass());